# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.sensors.date_time import DateTimeSensor


from jms_target_all.time_sensor.time_after_08_00 import time_after_08_00


time_after_08_15 = DateTimeSensor(
    task_id='time_after_08_15',
    pool='default_pool',
    target_time='{{ execution_date | date_add(1) | cst_ds }}T08:15:00+08:00',
    retries=0,
    mode='poke',
    execution_timeout=timedelta(hours=10),
    email=['yl_bigdata@yl-scm.com','time_sensor@yl-scm.com'],
)


time_after_08_15 << time_after_08_00